package com.partsoft.dits.mq;

import org.apache.commons.pool.KeyedObjectPool;

import com.partsoft.dits.DataEdgeDescriptor;

/**
 * MQ队列监听上下文。
 */
public interface MQQueueListenerContext {
	
	KeyedObjectPool getQueueManagerPool();
	
	String getQueueManager();
	
	String getQueue();
	
	long getRetrieveInterval();
	
	DataEdgeDescriptor[] getDataDescriptors();

	void receiveData(DataEdgeDescriptor desc, byte[] sourceXML);
	
}
